package rabbitmq

import (
	"encoding/json"
	"fmt"
	"log"
)

func SimLpePublish(kill map[string]interface{}) error {
	// 创建RabbitMQ实例
	rabbitmq := NewRabbitMQSimple("kuteng")
	if rabbitmq == nil {
		return fmt.Errorf("创建RabbitMQ实例失败")
	}
	defer rabbitmq.Destory()

	// 记录发送的消息内容
	log.Printf("准备发送消息: %+v", kill)

	// 序列化消息
	message, err := json.Marshal(kill)
	if err != nil {
		return fmt.Errorf("消息序列化失败: %v", err)
	}

	// 发送消息
	rabbitmq.PublishSimple(message)
	log.Printf("消息发送成功: %s", string(message))
	return nil
}
